from kafka import consumer


class KConsumer:
    # KAFKA消费者类

    def __init__(self, topic: str = None):
        pass
